package cloud.xiguapi.ubas.constant;

import lombok.AllArgsConstructor;
import lombok.Getter;

/**
 * Flink任务名称常量接口
 *
 * @author 大大大西西瓜皮🍉
 * date: 2021-5-17 上午 12:08
 * desc:
 */
@Getter
@AllArgsConstructor
public enum JobNameConstant {

    /**
     * 离线热门商品统计分析Job
     */
    FILE_HOT_ITEMS("file-hot-items"),

    /**
     * Kafka流式热门商品统计分析Job
     */
    KAFKA_HOT_ITEMS("kafka-hot-items"),

    /**
     * SQL流式热门商品统计分析Job
     */
    SQL_HOT_ITEMS("sql-hot-items"),

    /**
     * 离线热门页面统计分析Job
     */
    FILE_HOT_PAGES("file-hot-items"),

    /**
     * Socket热门页面统计分析Job
     */
    SOCKET_HOT_PAGES("file-hot-items"),

    /**
     * Socket热门页面统计分析Job
     */
    FILE_PV("file-pv"),

    /**
     * 基于集合的离线UV统计分析Job
     */
    SET_UV("set-uv"),

    /**
     * 基于布隆过滤器的离线UV统计分析Job
     */
    BLOOM_UV("bloom-uv"),

    /**
     * 市场推广统计Job
     */
    CHANNEL_MARKETING("channel_marketing"),

    /**
     * 市场推广汇总统计Job
     */
    SUMMARY_MARKETING("summary_marketing"),

    /**
     * 广告点击统计
     */
    ADVERTISING("blacklist-province-advertising"),

    /**
     * 恶意登录检测
     */
    LOGIN_FAIL("timeliness-login-fail-detect");

    /**
     * Flink ExecutionEnvironment Job Name
     */
    private final String jobName;
}
